/**
 * 消息路由
 * 处理与消息相关的HTTP请求
 */
const express = require('express');
const router = express.Router();
const Message = require('../models/message');

/**
 * 获取消息列表
 * GET /api/messages
 */
router.get('/', async (req, res) => {
  try {
    // 查询最新的10条消息
    const messages = await Message.find().sort({ timestamp: -1 }).limit(10);
    res.json(messages);
  } catch (err) {
    // 处理查询错误
    res.status(500).json({ message: err.message });
  }
});

/**
 * 创建新消息
 * POST /api/messages
 */
router.post('/', async (req, res) => {
  // 创建消息实例
  const message = new Message({
    content: req.body.content
  });

  try {
    // 保存消息到数据库
    const newMessage = await message.save();
    res.status(201).json(newMessage);
  } catch (err) {
    // 处理保存错误
    res.status(400).json({ message: err.message });
  }
});

module.exports = router;